/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package sessions;

import entities.Documento;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import javax.ejb.Stateless;
import javax.ejb.LocalBean;

/**
 *
 * @author miniyo
 */
@Stateless
@LocalBean
public class SubirFicheroBean {

    // Add business logic below. (Right-click in editor and choose
    // "Insert Code > Add Business Method")
    public boolean subir(Documento doc)
    {
        ConexionBean dBean = new ConexionBean();
        //DatoInfo dato = new DatoInfo();
        Connection con = null;
        ResultSet rs = null;
        PreparedStatement pStatement = null;
        try {
            System.out.println("Email --> " + doc.getIdUsuario());
            System.err.println("Estamos en EJB SubirFichero");
            con = dBean.getConnection();
            String sql = "SELECT * FROM APP.FICHERO WHERE ID = ?";
            pStatement = con.prepareStatement(sql);
            //pStatement.setString(1, usuario.getEmail());
            //rs = pStatement.executeQuery();
            System.err.println("Estamos en EJB.subirfichero2");
            //System.err.println(rs.next());
            if (rs.next())
            {
                System.err.println("No se como definir este error." );
            } 
            else
            {
                //insert into APP.USUARIOS(nombre , apellidos,email,pass) values('d','d','d','d');
                //String insertString = "INSERT INTO APP.USUARIOS(NOMBRE, APELLIDOS, EMAIL, PASS) VALUES ('" + usuario.getNombre() + "','" + usuario.getApellidos() + "','" + usuario.getEmail() + "','" + usuario.getPassword() + "');";

                java.sql.Statement orden = con.createStatement();
                String insertString = "INSERT INTO APP.FICHERO( CONTENIDO) values('" + doc.getFichero() + "')";
                int res = orden.executeUpdate(insertString);
                System.out.println("res --> " + res);
                insertString = "INSERT INTO APP.USUARIOS_FICHEROS( ID_USUARIO,ID_FICHERO) values('" + doc.getIdUsuario() + "'" + doc.getId() + "')";
            }
        } 
        catch (Exception e)
        {
            System.out.println("Error --> " + e.getLocalizedMessage());

        }
        try
        {
            rs.close();
            pStatement.close();
            con.close();
            return true;
        } 
        catch (Exception ex)
        {
            System.out.println("Error en el cierre de la base de datos");
            return false;
        }
    }
}
